package com.apex.flink.stream;

import com.apex.flink.FlinkBaseSource;
import com.apex.flink.FlinkEnvironment;
import org.apache.flink.streaming.api.datastream.DataStream;

public interface FlinkStreamSource<T> extends FlinkBaseSource {
    DataStream<T> getData(FlinkEnvironment env);
}
